package org.qee.mq.kafka;


import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;

@Component
public class Consumer {

    @KafkaListener(topics = "${kafka.topic}")
    public void listen(String msg) {
        System.out.println("Received: " + msg);
    }

}
